9b76bd8b46da92072c1f8a38b1234988a8e6c0d5,gateway/src/main/java/com/continuuity/gateway/v2/handlers/stream/CachedStreamEvents.java,ProducerStreamEntries,flush,#,177

Before Change


        new StreamEntryToQueueEntryFunction(future, callbackExecutorService);

      try {
        streamEntries.drainTo(entries);
        if (entries.isEmpty()) {
          return;
        }

After Change



    public synchronized void flush() {
      List<StreamEntry> entries = Lists.newArrayListWithExpectedSize(streamEntries.size());
      streamEntries.drainTo(entries);
      if (entries.isEmpty()) {
        return;
      }